package com.lagou.zk.zkconfigure.zkclient;

import com.lagou.zk.zkconfigure.ZkconfigureApplication;
import org.I0Itec.zkclient.IZkDataListener;

/**
 * zk数据变化监听器
 */
public class LagouDataListener implements IZkDataListener {
    /*
        当节点数据内容发生变化时，执行的回调方法
        s: path
        o: 变化后的节点内容
     */
    public void handleDataChange(String s, Object o) throws Exception {
        String confstr= (String)o;
        ZkconfigureApplication.createConnPool(confstr);
        System.out.println(s+"该节点内容被更新，更新的内容"+o);
    }

    /*
        当节点被删除时，会执行的回调方法
        s : path
     */
    public void handleDataDeleted(String s) throws Exception {
        System.out.println(s+"该节点被删除");
    }
}
